package mq

import (
	"os"

	"yingsheng.com/go-api-server"
	"yingsheng.com/go-api-server/log"
	"yingsheng.com/go-api-server/mq"
)

type mqConsumer struct{}

func (*mqConsumer) HandlerMessage(msg []byte) error {
	log.Logger.Info("消息处理中：", string(msg))
	return nil

	//调用bll处理消息
	//return bll.Test.Update(0, "")
}

func init() {
	apiserver.Wait()

	testConsumer1 := &mqConsumer{}
	//testConsumer2 := &mqConsumer{}

	// 创建消息消费者对象
	_, err := mq.NewConsumer("nsq", "example", "ch1", testConsumer1)
	if err != nil {
		log.Logger.Critical("Consumer New Error: ", err)
		os.Exit(1)
	} else {
		log.Logger.Info("Consumer running...")
	}

	// 多通道接收副本消息，进行多样化处理
	//	_, err = mq.NewConsumer("nsq", "example", "ch2", testConsumer2)
	//	if err != nil {
	//		log.Logger.Critical("Consumer New Error: ", err)
	//		os.Exit(1)
	//	} else {
	//		log.Logger.Info("Consumer running...")
	//	}
}
